package com.mojo.web.kafka;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.MessageChannel;

/**
 * kafka消息接收器
 *
 * @author <a href="mailto:sjj@jianzhimao.com">mojo</a>
 * copyright (C), 2013-2022, 广州九尾信息科技有限公司
 * @date 2022/2/26 15:55
 */
public interface MySink {
    @Input("myinput")
    MessageChannel myInput();
}
